package com.cold.demo.rabbitmq.demo2.$2;

import com.cold.demo.rabbitmq.utils.ConnectionUtils;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

/**
 * 直接发送到某一个队列中去
 * @author: zyc
 */
public class Publisher {

    public static void main(String[] args) throws Exception{
        Connection connection = ConnectionUtils.getConnection();
        Channel    channel    = connection.createChannel();
        // 绑定队列
        // 1、队列名称
        // 2、是否持久化消息
        // 3、是否独占队列
        // 4、是否自动删除队列
        // 5、参数–队列的其他属性（构造参数）
//        channel.queueDeclare("test1", false, false, false, null);

        // 发送消息
        // 1、将消息发布到指定的交换机
        // 2、routingKey – 路由
        // 3、消息的其他属性
        // 4、正文
        for (int i = 0; i < 10; i++) {
            channel.basicPublish("", "test1", null, (System.currentTimeMillis() + "这里是消息数据" + i).getBytes());
        }
        channel.close();
        connection.close();

    }
}
